#!/usr/bin/env python

import rospy
from xjtu_manipulation.msg import ManiProcessCmd

def callback(data):
    rospy.loginfo(rospy.get_caller_id() + " I heard %s", data)

if __name__ == '__main__':
    try:
        rospy.init_node('custom_msg_talker', anonymous=True)
        pub = rospy.Subscriber('mani_process', ManiProcessCmd, callback, queue_size=1)
        rospy.loginfo("Subscriber initialized, waiting for messages...")
        rospy.spin()
    except rospy.ROSInterruptException:
        pass